package com.sojson.util.mq.rabbit.code.bean;

import com.rabbitmq.client.Channel;
import com.rabbitmq.client.DefaultConsumer;

/**
 * 自定义消息的回调接口
 * 
 * @author liu
 * @date 2021-09-18
 */
public abstract class BaseCustomConsumer extends DefaultConsumer {

    private Channel channel;

    public BaseCustomConsumer(Channel channel) {
        super(channel);
        this.channel = channel;
    }

    @Override
    public Channel getChannel() {
        return channel;
    }

    public void setChannel(Channel channel) {
        this.channel = channel;
    }

}